package com.gmall.data.functions;

import com.gmall.data.pojo.LogBean;
import com.gmall.data.pojo.ResultBean;
import org.apache.flink.streaming.api.functions.KeyedProcessFunction;
import org.apache.flink.util.Collector;

public class RuleProcessFunctionV5 extends KeyedProcessFunction<String, LogBean, ResultBean> {
    @Override
    public void processElement(LogBean logBean, Context context, Collector<ResultBean> out) throws Exception {

    }
}
